package com.shujia.day17.tcp2;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) throws IOException {
        /*
            服务端不断接收客户端传入过来的数据，并回复一条消息
         */


        // 1.创建对应的socket  0-65535  0-1024系统内部使用

        ServerSocket serverSocket = new ServerSocket(9999);

        Socket socket = serverSocket.accept();  // 由于没有客户端进行连接 所以没有创建一个对应的socket 所以accept对当前线程进行阻塞
        System.out.println("==================帅哥在线聊天室启动了==================");

        while (true) {
            // 读取数据
            InputStream inputStream = socket.getInputStream();
            byte[] bytes = new byte[1024];
            int read = inputStream.read(bytes);
            String message = new String(bytes, 0, read);
            System.out.println("收到帅哥信息："+message);


            // 返回数据
            OutputStream outputStream = socket.getOutputStream();
            outputStream.write("服务端已经接收到数据".getBytes());
            outputStream.flush();
        }

//        socket.close();
    }
}
